package task

import (
	"k8s-admin/models"
	task2 "k8s-admin/service/task"
	"k8s-admin/utils"

	"github.com/gin-gonic/gin"
)

/*周期任务*/
func TimerCreate(ctx *gin.Context) {
	req := models.TimerReq{}
	if err := ctx.ShouldBindJSON(&req); err != nil {
		utils.ReturnContext(ctx).Failed("失败", err.Error())
	} else {
		err := task2.NewTimerInterface().Create(&req)
		if err != nil {
			utils.ReturnContext(ctx).Failed("失败", err)
		} else {
			utils.ReturnContext(ctx).Successful("成功", "创建成功")
		}
	}
}
func TimerLists(ctx *gin.Context) {

	list, err := task2.NewTimerInterface().List()
	if err != nil {
		utils.ReturnContext(ctx).Failed("失败", err)
	} else {
		utils.ReturnContext(ctx).Successful("成功", list)
	}

}

func TimerStart(ctx *gin.Context) {
	timer_number := ctx.Param("timer_number")
	_, err := task2.NewTimerInterface().StartTimer(timer_number)
	if err != nil {
		utils.ReturnContext(ctx).Failed("失败", err)
	} else {
		utils.ReturnContext(ctx).Successful("成功", "执行成功，详细请查看日志")
	}
}
